package com.unism.uniMeterage.meterage.stream.version1_1.listener;

import com.unism.uniMeterage.meterage.stream.MessageEvent;
import com.unism.uniMeterage.meterage.stream.MessageListener;

/**
 * @author liuc
 * 监听Send事件的句柄函数
 */
public class SendListener implements MessageListener {
    @Override
    public void doMessage(MessageEvent e) {
         if(e.getStatus() == MessageEvent.MessageStatus.SENT){
             System.out.println("时间:"+System.currentTimeMillis()+" 监听到Send事件,内容为:"+e.getSource());
         }
    }
}
